package com.xazenith.kfk.concurrent;

import java.util.concurrent.*;

/**
 * ...
 *
 * @author zhou wei
 * @version 0.1
 * @since 2020-07-07
 */
public final class ConsumerConcurrentContext {

    private ConsumerConcurrentContext() {}

    private static final Integer nThreads = 3;

    public static final ScheduledExecutorService SCHEDULED_THREAD_POOL_EXECUTOR = new ScheduledThreadPoolExecutor(nThreads, (ThreadFactory) Thread::new);
}
